package com.netty.example.time.firstsolusion;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

import java.util.Date;

/**
 * 如您所见，它与服务器端代码并没有真正的区别。
 * 怎么样ChannelHandler实现？它应该从服务器接收一个32位整数，将其转换为人类可读的格式，打印转换后的时间，然后关闭连接：
 */
public class TimeClientHandler extends ChannelInboundHandlerAdapter {
    private ByteBuf buf;
    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        /*
        1.一个ChannelHandler有两个生命周期侦听器方法：handlerAdded()和handlerRemoved()。
        您可以执行任意（取消）初始化任务，只要它长时间不阻塞即可。
         */
        ctx.alloc().buffer(4);
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        /*
        1.一个ChannelHandler有两个生命周期侦听器方法：handlerAdded()和handlerRemoved()。
        \您可以执行任意（取消）初始化任务，只要它长时间不阻塞即可。
         */
        buf.release();
        buf = null;
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        ByteBuf m = (ByteBuf) msg;
        /*
        2.首先，应将所有接收到的数据累加到中buf。
         */
        buf.writeBytes(m);
        m.release();

        /*
        3.然后，处理程序必须检查是否buf有足够的数据（在此示例中为4个字节），
        然后继续进行实际的业务逻辑。否则，channelRead()当更多数据到达时
        ，Netty将再次调用该方法，最终将累加所有4个字节。
         */
        if (buf.readableBytes() >= 4) {
            long currentTimeMillis = (buf.readUnsignedInt() - 2208988800L) * 1000L;
            System.out.println(new Date(currentTimeMillis));
            ctx.close();
        }
    }


    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }
}
